package com.niit.user.service;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**自定义的Source接口，用于定义消息的输出通道
 * @author yaojianfeng
 */
public interface MySource {
    String OUTPUT1 = "output1";
    String OUTPUT2 = "output2";
    /**
     * 定义消息的输出通道1
     * @return MessageChannel
     */
    @Output(MySource.OUTPUT1)
    MessageChannel output1();

    /**
     * 定义消息的输出通道2
     * @return MessageChannel
     */
    @Output(MySource.OUTPUT2)
    MessageChannel output2();
}